package com.hsylient.redis.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class RedisClusterService {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    public void testCluster() {
        String testKey = "cluster:test:key";
        String testValue = "Hello, Spring Boot Redis Cluster!";

        // 读取数据
        String retrievedValue = (String) redisTemplate.opsForValue().get(testKey);
        System.out.println("成功读取数据：" + testKey + " -> " + retrievedValue);

//        // 写入数据
//        redisTemplate.opsForValue().set(testKey, testValue);
//        System.out.println("成功写入数据：" + testKey + " -> " + testValue);
//
//        // 读取数据
//        String retrievedValue = (String) redisTemplate.opsForValue().get(testKey);
//        System.out.println("成功读取数据：" + testKey + " -> " + retrievedValue);
//
//        // 验证一致性
//        if (testValue.equals(retrievedValue)) {
//            System.out.println("Redis 集群验证通过！");
//        } else {
//            System.err.println("Redis 集群数据不一致！");
//        }
    }
}
